# 在应用目录下创建tasks.py，存放定时执行的函数
from akshare_analysis.qihuo_current import fetch_futures_current_data
from akshare_analysis.qihuo_list_his import fetch_futures_his_data
from akshare_analysis.ak_code_config import read_futures_config
import logging

# 获取自定义日志器（与 settings.py 中的 'app' 对应）
logger = logging.getLogger('app')


def task_test():
    """测试任务"""
    logger.info('start 测试任务开始执行')
    logger.info('end 测试任务执行完毕')

def pull_futures_history_data():
    """拉取期货历史行情数据的任务"""
    logger.info('start 测试任务开始执行  pull_futures_history_data')
    ak_code_data = read_futures_config()
    for row in ak_code_data:
        fetch_futures_his_data(row)
    logger.info('end 测试任务执行完毕  pull_futures_history_data')

def pull_futures_current_data():
    # 测试读取配置
    ak_code_data = read_futures_config()
    fetch_futures_current_data(ak_code_data)


